package cn.zwx.common.canal.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

import java.util.List;

/**
 * @author zhangwenxe
 */
@Data
@ConfigurationProperties(prefix = "cn.zwx.canal")
public class CanalPropertiesConfig {

    /**
     * 拉取批次
     */
    private Integer batchSize = 2000;
    /**
     * 服务端地址
     */
    private String serverAddr;

    /**
     * 账号
     */
    private String username;
    /**
     * 密码
     */
    private String password;

    /**
     * 是否集群
     */
    private boolean clusterEnabled;

    /**
     * instance 实例
     */
    private List<CanalInstance> instances;



    @Data
    public static class CanalInstance{

        /**
         * 实例名称
         */
        private String destination;
        /**
         * 订阅规则
         */
        private String subscribe;

        /**
         * 发送消息
         */
        private String topic;
    }



}
